package main

import (
	amqp "github.com/rabbitmq/amqp091-go"
	mq "go_test/amqp091-go_demo3"
)

func main() {
	name := "job_queue"
	addr := "amqp://user:password@182.92.212.121:5672/"
	mq.NewRabbitMQ(name, addr, func(deliveries <-chan amqp.Delivery) {
		// Consume messages
	})
}
